package com.soboot.common.config.mq;

import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;

public interface RocketConsumer {

    /**
     * 初始化消费者
     */
    public abstract void init();

    /**
     * 注册监听
     *
     * @param messageListener
     */
    public void registerMessageListener(MessageListenerConcurrently messageListener);
}
